package common;

import common.listener.Subscriber;

//事件发布者
public interface ShardedEventPublisher extends EventPublisher{

    long currentEventSize();

    void addSubscriber(Subscriber subscriber, Class<? extends Event> subscribeType);

    void removeSubscriber(Subscriber subscriber, Class<? extends Event> subscribeType);

}
